package com.cloud.rocketmq;

import org.springframework.stereotype.Component;

import java.lang.annotation.*;

/**
 * RocketMQ 事务消息注解
 *
 * @author yzj
 */
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Component
public @interface MQTransactionProducer {

    /**
     * 生产者发送组
     *
     * @return
     */
    String producerGroup();

    /**
     * 消息主题
     *
     * @return
     */
    String topic();

    /**
     * 消息标签
     *
     * @return
     */
    String tag();

}
